package cn.itcast.zt.demo01;

import com.lmax.disruptor.EventHandler;

/**
 * 这个类就是一个处理器，也可以说是消费者
 * create by zhangtian3 on 2018/10/9
 */
public class StringEventHandler implements EventHandler<StringEvent> {
    // 事件的处理器，也就是消费者，这里模拟的是将数据打印处理
    @Override
    public void onEvent(StringEvent stringEvent, long sequence, boolean endOfBatch) throws Exception {
        System.out.println("StringEventHandler(消费者):  "  + stringEvent +", sequence= "+sequence+",endOfBatch="+endOfBatch);
    }
}
